package com.atguigu.wc;

import org.apache.flink.api.java.DataSet;
import org.apache.flink.api.java.ExecutionEnvironment;

//批处理word count
public class WordCount
{
    public static void main(String[] args)
    {
        //创建执行环境
        ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();

        String inputPath="E:\\work\\workspace\\FlinkTotorial\\src\\main\\resources\\hello.txt";
        DataSet<String> inputDataSet = env.readTextFile(inputPath);

        //数据处理
        System.out.println("TODO");
    }
}
